home *** CD-ROM | disk | FTP | other *** search
- package com.xibaro.chat;
-
- import java.io.IOException;
- import javax.microedition.io.Connector;
- import javax.microedition.io.Datagram;
- import javax.microedition.io.DatagramConnection;
-
- public class Conexion extends Thread {
- private String server;
- private String port;
- private Cliente jefe;
- private DatagramConnection socket;
- private String dir;
- private boolean seguir;
-
- public Conexion(Cliente var1, String var2, String var3) {
- this.jefe = var1;
- this.server = var2;
- this.port = var3;
- this.dir = "datagram://" + var2 + ":" + var3;
- this.seguir = true;
- }
-
- public boolean inicia() {
- boolean var1 = false;
-
- try {
- this.socket = (DatagramConnection)Connector.open(this.dir);
- } catch (Exception var3) {
- this.jefe.mensajeEstado("Error estableciendo conexi├│n");
- var1 = true;
- }
-
- if (!var1) {
- ((Thread)this).start();
- return true;
- } else {
- return false;
- }
- }
-
- public void run() {
- for(Datagram var1 = null; this.seguir; this.jefe.recibido(var1)) {
- try {
- var1 = this.socket.newDatagram(this.socket.getMaximumLength());
- this.socket.receive(var1);
- } catch (IOException var4) {
- this.jefe.mensajeEstado("Error de I/O al recibir");
- } catch (IllegalArgumentException var5) {
- this.jefe.mensajeEstado("Error al construir datagrama en recpci├│n");
- }
- }
-
- }
-
- public void parar() {
- this.seguir = false;
- }
-
- public void envia(String var1) {
- try {
- Datagram var2 = this.socket.newDatagram(var1.getBytes(), var1.getBytes().length, this.dir);
- this.socket.send(var2);
- } catch (IOException var3) {
- this.jefe.mensajeEstado("Error I/O al enviar");
- }
-
- }
-
- public void cerrar() {
- this.seguir = false;
-
- try {
- this.socket.close();
- } catch (IOException var2) {
- }
-
- this.socket = null;
- }
- }
-